package schedule

import "context"
import "github.com/beherochuling/beesoft_api/app/helper/net"

func mqttSubscribe(ctx context.Context) {
	go func() {
		endpoint := "mqtt://111.229.207.234:1883"

		net.NewMqtt(ctx).
			Endpoint(endpoint).
			Subscribe()
	}()
}
